package cn.com.tt.flink.sql.engine.pojo.sql.factory;

import cn.com.tt.flink.sql.engine.pojo.sql.AbstractBmFlinkSql;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;

public interface BmSqlFactory {
    AbstractBmFlinkSql createSql(String sql, StreamTableEnvironment tableEnv);
}
